package com.newly.api.business.feign;

import com.newly.common.base.constants.ServerUriConstant;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@Api(tags = "MQTT-消息上报接收处理")
@FeignClient(path = ServerUriConstant.NEWLY_BUSINESS_MQTT_Receiver, name = ServerUriConstant.NEWLY_BUSINESS_SERVICE_NAME)
public interface MQTTReceiverClient {

    @ApiOperation("接收正常车辆上报信息")
    @GetMapping("/register")
    void register(@RequestParam(value = "topic", required = true) String topic,
                        @RequestParam(value = "message", required = true) String message);

    @ApiOperation("接收正常车辆上报信息")
    @GetMapping("/setVehicleInfo")
    void setVehicleInfo(@RequestParam(value = "topic", required = true) String topic,
                        @RequestParam(value = "message", required = true) String message);

    @ApiOperation("接收非法车辆上报信息")
    @GetMapping("/setIllegalVehicleInfo")
    void setIllegalVehicleInfo(@RequestParam(value = "topic", required = true) String topic,
                               @RequestParam(value = "message", required = true) String message);


}
